package com.minimalist.common.config.rocketmq.consumer;

/**
 * @author 11987
 */
//@Service
//@RocketMQMessageListener(consumerGroup = "string_consumer", topic = "TestTopic")
//public class RocketMqConsumer implements RocketMQListener<MessageExt>{
//    private static final Logger log = LoggerFactory.getLogger(RocketMqConsumer.class);
//
//
//    @Override
//    public void onMessage(MessageExt messageExt){
//        log.info("收到消息: {}", messageExt);
//    }
//}

